www.gusucode.com > Piwik 网站流量统计系统 v2.9.1PHP源码程序 > Piwik 网站流量统计系统 v2.9.1/How to install Piwik.html/piwik/core/Db/Adapter/Mysqli.php
<?php /** * Piwik - free/libre analytics platform * * @link http://piwik.org * @license http://www.gnu.org/licenses/gpl-3.0.html GPL v3 or later * */ namespace Piwik\Db\Adapter; use Exception; use Piwik\Config; use Piwik\Db\AdapterInterface; use Piwik\Piwik; use Zend_Config; use Zend_Db_Adapter_Mysqli; /** */ class Mysqli extends Zend_Db_Adapter_Mysqli implements AdapterInterface { /** * Constructor * * @param array|Zend_Config $config database configuration */ public function __construct($config) { // Enable LOAD DATA INFILE $config['driver_options'][MYSQLI_OPT_LOCAL_INFILE] = true; parent::__construct($config); } /** * Reset the configuration variables in this adapter. */ public function resetConfig() { $this->_config = array(); } /** * Return default port. * * @return int */ public static function getDefaultPort() { return 3306; } /** * Check MySQL version * * @throws Exception */ public function checkServerVersion() { $serverVersion = $this->getServerVersion(); $requiredVersion = Config::getInstance()->General['minimum_mysql_version']; if (version_compare($serverVersion, $requiredVersion) === -1) { throw new Exception(Piwik::translate('General_ExceptionDatabaseVersion', array('MySQL', $serverVersion, $requiredVersion))); } } /** * Check client version compatibility against database server * * @throws Exception */ public function checkClientVersion() { $serverVersion = $this->getServerVersion(); $clientVersion = $this->getClientVersion(); // incompatible change to DECIMAL implementation in 5.0.3 if (version_compare($serverVersion, '5.0.3') >= 0 && version_compare($clientVersion, '5.0.3') < 0 ) { throw new Exception(Piwik::translate('General_ExceptionIncompatibleClientServerVersions', array('MySQL', $clientVersion, $serverVersion))); } } /** * Returns true if this adapter's required extensions are enabled * * @return bool */ public static function isEnabled() { $extensions = @get_loaded_extensions(); return in_array('mysqli', $extensions); } /** * Returns true if this adapter supports blobs as fields * * @return bool */ public function hasBlobDataType() { return true; } /** * Returns true if this adapter supports bulk loading * * @return bool */ public function hasBulkLoader() { return true; } /** * Test error number * * @param Exception $e * @param string $errno * @return bool */ public function isErrNo($e, $errno) { if (is_null($this->_connection)) { if (preg_match('/(?:\[|\s)([0-9]{4})(?:\]|\s)/', $e->getMessage(), $match)) { return $match[1] == $errno; } return mysqli_connect_errno() == $errno; } return mysqli_errno($this->_connection) == $errno; } /** * Execute unprepared SQL query and throw away the result * * Workaround some SQL statements not compatible with prepare(). * See http://framework.zend.com/issues/browse/ZF-1398 * * @param string $sqlQuery * @return int Number of rows affected (SELECT/INSERT/UPDATE/DELETE) */ public function exec($sqlQuery) { $rc = mysqli_query($this->_connection, $sqlQuery); $rowsAffected = mysqli_affected_rows($this->_connection); if (!is_bool($rc)) { mysqli_free_result($rc); } return $rowsAffected; } /** * Is the connection character set equal to utf8? * * @return bool */ public function isConnectionUTF8() { $charset = mysqli_character_set_name($this->_connection); return $charset === 'utf8'; } /** * Get client version * * @return string */ public function getClientVersion() { $this->_connect(); $version = $this->_connection->server_version; $major = (int)($version / 10000); $minor = (int)($version % 10000 / 100); $revision = (int)($version % 100); return $major . '.' . $minor . '.' . $revision; } }